package main

//
//import (
//	"context"
//	"fmt"
//	"github.com/segmentio/kafka-go"
//	"github.com/segmentio/kafka-go/sasl/plain"
//	"os"
//)
//
//const ip string = "120.46.139.204:29193"
//const username string = "aerosatlink"
//const password string = "aerosatlink"
//
//func main() {
//	mechanism := plain.Mechanism{
//		Username: username,
//		Password: password,
//	}
//
//	r := kafka.NewReader(kafka.ReaderConfig{
//		Brokers:  []string{ip},
//		Topic:    "B-8331T",
//		MaxBytes: 10e6, // 10MB
//	})
//
//	for {
//		m, err := r.FetchMessage(context.Background())
//		if err != nil {
//			fmt.Printf("read err: %s\n", err.Error())
//			break
//		}
//		fmt.Printf("message at offset %d: %s = %s\n",
//			m.Offset, string(m.Key), string(m.Value))
//	}
//
//	if err := r.Close(); err != nil {
//		fmt.Printf("failed to close reader: %s", err)
//		os.Exit(1)
//	}
//}
